/*package com.easy.test;

import com.aliyun.openservices.ons.api.Message;
import com.aliyun.openservices.ons.api.ONSFactory;
import com.aliyun.openservices.ons.api.PropertyKeyConst;
import com.aliyun.openservices.ons.api.order.ConsumeOrderContext;
import com.aliyun.openservices.ons.api.order.MessageOrderListener;
import com.aliyun.openservices.ons.api.order.OrderAction;
import com.aliyun.openservices.ons.api.order.OrderConsumer;
import java.util.Properties;

public class YUNConsumerClient {
	public static void main(String[] args) {
		Properties properties = new Properties();
		properties.put(PropertyKeyConst.ConsumerId, "CID_100000001");// 您在控制台创建的
																		// Consumer
																		// ID
		properties.put(PropertyKeyConst.AccessKey, "LTAIZ3CsZfM34Fnt");
		properties.put(PropertyKeyConst.SecretKey, "N2iajoVyQ6u6FDuOUzI28LxRIfoNYK");

		properties.put(PropertyKeyConst.SuspendTimeMillis, "100"); // 顺序消息消费失败进行重试前的等待时间
																	// 单位(毫秒)
		properties.put(PropertyKeyConst.MaxReconsumeTimes, "20"); // 消息消费失败时的最大重试次数
		// 在订阅消息前，必须调用 start 方法来启动 Consumer，只需调用一次即可。
		OrderConsumer consumer = ONSFactory.createOrderedConsumer(properties);
		consumer.subscribe(
				// Message所属的Topic
				"shenmatopic3",
				// 订阅指定Topic下的Tags：
				// 1. * 表示订阅所有消息
				// 2. TagA || TagB || TagC 表示订阅TagA 或 TagC 或 TagD 的消息
				"*", new MessageOrderListener() {
					*//**
					 * 1. 消息消费处理失败或者处理出现异常，返回OrderAction.Suspend<br>
					 * 2. 消息处理成功，返回与返回OrderAction.Success
					 *//*
					@Override
					public OrderAction consume(Message message, ConsumeOrderContext context) {
						System.out.println(new String(message.getBody()));
						return OrderAction.Success;
					}
				});
		consumer.start();
	}
}
*/